//package com.zhangdi.mgsync.core.service;
//
//import com.iowl.search.mgdb.mq.DataInfo;
//import com.zhangdi.mgsync.core.dto.ErrorLog;
//import com.zhangdi.mgsync.core.dto.OPToken;
//import com.zhangdi.mgsync.core.mapper.ErrorMapper;
//import com.zhangdi.mgsync.core.mapper.TokenMapper;
//import org.apache.commons.lang3.StringUtils;
//import org.springframework.beans.factory.annotation.Autowired;
//import org.springframework.stereotype.Component;
//
//import java.util.Date;
//
///**
// * @author zhangdi
// * @version 1.0
// * @date 2022.2.8 23:00
// */
//@Component
//public class LogServiceImpl implements LogService {
//    @Autowired
//    ErrorMapper errorMapper;
//    @Autowired
//    TokenMapper tokenMapper;
//
//    @Override
//    public void error(String key, DataInfo dataInfo, String msg) {
//        ErrorLog log = new ErrorLog();
//        log.setColl(key);
//        if(null != dataInfo) {
//            log.setDataId(dataInfo.getId());
//            log.setOp(dataInfo.getOp());
//            log.setDataTime(dataInfo.getDt());
//        }
//
//        log.setMsg(msg);
//        log.setAddTime(new Date().getTime());
//        errorMapper.insert(log);
//    }
//
//    @Override
//    public void saveToken(String key, String token) {
//        tokenMapper.insert(new OPToken(key, token));
//    }
//
//    @Override
//    public String token(String key) {
//        if (StringUtils.isBlank(key)) {
//            return null;
//        }
//        OPToken opToken = tokenMapper.selectById(key);
//        if (opToken == null) {
//            return null;
//        }
//        return opToken.getToken();
//    }
//}
